package com.intct.func;

import org.apache.flink.table.functions.ScalarFunction;

import java.sql.Timestamp;

/**
 * @author gufg
 * @since 2025-10-25 16:38
 */
public class CurrentTime extends ScalarFunction {
    public Timestamp eval() {
        return  new Timestamp(System.currentTimeMillis());
    }

   /* public static void main(String[] args) {
        System.out.println(new Current_time().eval());
    }*/
}
